Telegram channel to Readeck & Hoarder
工作流概述
这是一个包含15个节点的复杂工作流，主要用于自动化处理各种任务。
工作流源代码
{
"id": "Gd4MsAZGnSGfBwaw",
"meta": {
"instanceId": "8fb543b511022c43ab705107ba101545bb8b0fdb9bd6ebc4cca28dc9591a036e"
},
"name": "Telegram channel to Readeck & Hoarder",
"tags": [],
"nodes": [
{
"id": "6e50d52e-8b9e-4c92-82a1-af366c7a2ccf",
"name": "Schedule Trigger",
"type": "n8n-nodes-base.scheduleTrigger",
"position": [
-440,
-700
],
"parameters": {
"rule": {
"interval": [
{
"field": "hours"
}
]
}
},
"typeVersion": 1.2
},
{
"id": "bb7430a2-a7b7-47f2-9ba3-a3e43c8da004",
"name": "Split Out",
"type": "n8n-nodes-base.splitOut",
"position": [
-100,
-120
],
"parameters": {
"options": {},
"fieldToSplitOut": "bookmarks"
},
"typeVersion": 1
},
{
"id": "922aeb0b-29b1-46c6-9b18-76c02eca5a9e",
"name": "Sticky Note",
"type": "n8n-nodes-base.stickyNote",
"position": [
-460,
-480
],
"parameters": {
"width": 1120,
"height": 220,
"content": "## Readeck"
},
"typeVersion": 1
},
{
"id": "64d4ca0b-2c16-441e-9461-5707be877132",
"name": "Sticky Note1",
"type": "n8n-nodes-base.stickyNote",
"position": [
-220,
-740
],
"parameters": {
"width": 480,
"height": 200,
"content": "## Telegram"
},
"typeVersion": 1
},
{
"id": "13ae24ec-ac11-470a-bad4-76403861f632",
"name": "Sticky Note2",
"type": "n8n-nodes-base.stickyNote",
"position": [
-460,
-180
],
"parameters": {
"width": 1120,
"height": 220,
"content": "## Hoarder"
},
"typeVersion": 1
},
{
"id": "c606f434-d37b-4406-997a-1e7f17319281",
"name": "not_saved_links_hd",
"type": "n8n-nodes-base.code",
"position": [
260,
-120
],
"parameters": {
"jsCode": "const linksCanalItems = $('channel_links_tg').all();
const saved_links_items = $('saved_links_hd').all();
// Extract links
const saved_links = new Set(
saved_links_items.map(item => String(item.json.content.url))
);
// Filter
const filteredLinks = linksCanalItems.filter(item => {
return !saved_links.has(String(item.json.url));
});
return filteredLinks;
"
},
"typeVersion": 2
},
{
"id": "d0f61836-798c-4835-ae8f-8f184b6720ed",
"name": "not_saved_links_rd",
"type": "n8n-nodes-base.code",
"position": [
260,
-420
],
"parameters": {
"jsCode": "const linksCanalItems = $('channel_links_tg').all();
const saved_links_items = $('saved_links_rd').all();
// Extract urls
const saved_urls = new Set(
saved_links_items.map(item => String(item.json.url))
);
// Filter
const filteredLinks = linksCanalItems.filter(item => {
return !saved_urls.has(String(item.json.url));
});
return filteredLinks;
"
},
"typeVersion": 2
},
{
"id": "f33349a7-361a-4b0f-844b-1ca5ded2aeab",
"name": "saved_links_rd",
"type": "n8n-nodes-base.set",
"position": [
80,
-420
],
"parameters": {
"options": {},
"assignments": {
"assignments": [
{
"id": "8c6f3806-0fb8-4c76-a0bc-19b588717430",
"name": "id",
"type": "string",
"value": "={{ $json.id }}"
},
{
"id": "ef41cba3-2844-479c-9467-6b94ae24c98b",
"name": "url",
"type": "string",
"value": "={{ $json.url }}"
}
]
}
},
"typeVersion": 3.4
},
{
"id": "63d45b19-e878-418e-8eb5-c16b50af9669",
"name": "save_link_rd",
"type": "n8n-nodes-base.httpRequest",
"position": [
460,
-420
],
"parameters": {
"url": "={{$env.READECK_SERVER}}/api/bookmarks",
"method": "POST",
"options": {},
"sendBody": true,
"sendHeaders": true,
"bodyParameters": {
"parameters": [
{
"name": "url",
"value": "={{ $json.url }}"
}
]
},
"headerParameters": {
"parameters": [
{
"name": "accept",
"value": "application/json"
},
{
"name": "authorization",
"value": "=Bearer {{$env.READECK_API_KEY}}"
}
]
}
},
"typeVersion": 4.2
},
{
"id": "9416a858-1a25-4c3e-a49e-153118c268a7",
"name": "save_link_hd",
"type": "n8n-nodes-base.httpRequest",
"position": [
460,
-120
],
"parameters": {
"url": "={{$env.HOARDER_SERVER}}/api/v1/bookmarks",
"method": "POST",
"options": {},
"sendBody": true,
"sendHeaders": true,
"bodyParameters": {
"parameters": [
{
"name": "type",
"value": "link"
},
{
"name": "url",
"value": "={{ $json.url }}"
}
]
},
"headerParameters": {
"parameters": [
{
"name": "Authorization",
"value": "=Bearer {{$env.HOARDER_API_KEY}}"
}
]
}
},
"typeVersion": 4.2
},
{
"id": "13693467-cd75-4774-9072-832419606ab2",
"name": "get_links_rd",
"type": "n8n-nodes-base.httpRequest",
"position": [
-280,
-420
],
"parameters": {
"url": "={{$env.READECK_SERVER}}/api/bookmarks",
"options": {},
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "accept",
"value": "application/json"
},
{
"name": "authorization",
"value": "=Bearer {{$env.READECK_API_KEY}}"
}
]
}
},
"typeVersion": 4.2,
"alwaysOutputData": true
},
{
"id": "e4ed315d-d065-425a-b30d-eca1509670cc",
"name": "get_links_hd",
"type": "n8n-nodes-base.httpRequest",
"position": [
-280,
-120
],
"parameters": {
"url": "={{$env.HOARDER_SERVER}}/api/v1/bookmarks",
"options": {},
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Authorization",
"value": "=Bearer {{$env.HOARDER_API_KEY}}"
}
]
}
},
"typeVersion": 4.2,
"alwaysOutputData": true
},
{
"id": "f54d9a4d-f00b-41bf-988a-8920d0046424",
"name": "saved_links_hd",
"type": "n8n-nodes-base.set",
"position": [
80,
-120
],
"parameters": {
"options": {},
"assignments": {
"assignments": [
{
"id": "b07ce8e5-0b67-4c9c-831a-7a52f92f5744",
"name": "content.url",
"type": "string",
"value": "={{ $json.content.url }}"
}
]
}
},
"typeVersion": 3.4
},
{
"id": "d4e83b9d-5988-46f4-b853-86daec274dba",
"name": "channel_links_tg",
"type": "n8n-nodes-base.code",
"position": [
120,
-700
],
"parameters": {
"jsCode": "// Define the chatId from the environment variable
const chatId = parseInt($env.TG_SHERLINK_ID, 10);
// Access the \"result\" field from the previous node's output
const updates = $node[\"channel_items_tg\"].json[\"result\"];
// Check if \"result\" is an array
if (!Array.isArray(updates)) {
return []; // Return empty if there are no messages
}
// Filter and process the messages
const filteredUpdates = updates
.map(update => {
// Ensure message from the specified channel
if (update.channel_post && update.channel_post.chat && update.channel_post.chat.id === chatId) {
return {
id: update.channel_post.message_id,
url: update.channel_post.text
};
}
return null;
})
.filter(item => item !== null) // Filter nulls
.filter(item => {
// Filter only with hyperlink in text
const text = item.url || \"\"; // Defined text
return /https?:\/\/[^\s]+/.test(text); // hyperlink
});
// Convert each array element into an individual item
return filteredUpdates.map(update => ({ json: update }));
"
},
"typeVersion": 2,
"alwaysOutputData": false
},
{
"id": "ca306aed-e682-4c35-a257-3b65bcfde895",
"name": "channel_items_tg",
"type": "n8n-nodes-base.httpRequest",
"position": [
-80,
-700
],
"parameters": {
"url": "=https://api.telegram.org/bot{{$env.TG_SHERLINK_BOT_TOKEN}}/getUpdates",
"options": {},
"sendQuery": true,
"queryParameters": {
"parameters": [
{}
]
}
},
"typeVersion": 4.2
}
],
"active": true,
"pinData": {},
"settings": {
"callerPolicy": "workflowsFromSameOwner",
"executionOrder": "v1"
},
"versionId": "85dd3731-0772-4b8b-b828-ae6a034d5419",
"connections": {
"Split Out": {
"main": [
[
{
"node": "saved_links_hd",
"type": "main",
"index": 0
}
]
]
},
"get_links_hd": {
"main": [
[
{
"node": "Split Out",
"type": "main",
"index": 0
}
]
]
},
"get_links_rd": {
"main": [
[
{
"node": "saved_links_rd",
"type": "main",
"index": 0
}
]
]
},
"save_link_hd": {
"main": [
[]
]
},
"save_link_rd": {
"main": [
[]
]
},
"saved_links_hd": {
"main": [
[
{
"node": "not_saved_links_hd",
"type": "main",
"index": 0
}
]
]
},
"saved_links_rd": {
"main": [
[
{
"node": "not_saved_links_rd",
"type": "main",
"index": 0
}
]
]
},
"Schedule Trigger": {
"main": [
[
{
"node": "channel_items_tg",
"type": "main",
"index": 0
}
]
]
},
"channel_items_tg": {
"main": [
[
{
"node": "channel_links_tg",
"type": "main",
"index": 0
}
]
]
},
"channel_links_tg": {
"main": [
[
{
"node": "get_links_rd",
"type": "main",
"index": 0
},
{
"node": "get_links_hd",
"type": "main",
"index": 0
}
]
]
},
"not_saved_links_hd": {
"main": [
[
{
"node": "save_link_hd",
"type": "main",
"index": 0
}
]
]
},
"not_saved_links_rd": {
"main": [
[
{
"node": "save_link_rd",
"type": "main",
"index": 0
}
]
]
}
}
}功能特点
- 自动检测新邮件
- AI智能内容分析
- 自定义分类规则
- 批量处理能力
- 详细的处理日志
技术分析
节点类型及作用
- Scheduletrigger
- Splitout
- Stickynote
- Code
- Set
复杂度评估
配置难度：
维护难度：
扩展性：
实施指南
前置条件
- 有效的Gmail账户
- n8n平台访问权限
- Google API凭证
- AI分类服务订阅
配置步骤
- 在n8n中导入工作流JSON文件
- 配置Gmail节点的认证信息
- 设置AI分类器的API密钥
- 自定义分类规则和标签映射
- 测试工作流执行
- 配置定时触发器（可选）
关键参数
| 参数名称 | 默认值 | 说明 |
|---|---|---|
| maxEmails | 50 | 单次处理的最大邮件数量 |
| confidenceThreshold | 0.8 | 分类置信度阈值 |
| autoLabel | true | 是否自动添加标签 |
最佳实践
优化建议
- 定期更新AI分类模型以提高准确性
- 根据邮件量调整处理批次大小
- 设置合理的分类置信度阈值
- 定期清理过期的分类规则
安全注意事项
- 妥善保管API密钥和认证信息
- 限制工作流的访问权限
- 定期审查处理日志
- 启用双因素认证保护Gmail账户
性能优化
- 使用增量处理减少重复工作
- 缓存频繁访问的数据
- 并行处理多个邮件分类任务
- 监控系统资源使用情况
故障排除
常见问题
邮件未被正确分类
检查AI分类器的置信度阈值设置，适当降低阈值或更新训练数据。
Gmail认证失败
确认Google API凭证有效且具有正确的权限范围，重新进行OAuth授权。
调试技巧
- 启用详细日志记录查看每个步骤的执行情况
- 使用测试邮件验证分类逻辑
- 检查网络连接和API服务状态
- 逐步执行工作流定位问题节点
错误处理
工作流包含以下错误处理机制：
- 网络超时自动重试（最多3次）
- API错误记录和告警
- 处理失败邮件的隔离机制
- 异常情况下的回滚操作